package com.example.messagequeue.common;import com.example.messagequeue.mqserver.core.BasicPropertise;import java.io.IOException;/** * 消费执行的回调函数 */@FunctionalInterfacepublic interface Consumer {    void handleDelivery(String consumerTag, BasicPropertise basicPropertise,byte[] body) throws MQException, IOException;}